/**
 * 数据库连接工具模块
 * @author HalRui
 * @version 1.0.0
 * @description 提供数据库连接功能，基于连接池管理
 * @date 2025年9月27日
 */

const connectionPool = require('./connection-pool');

/**
 * 连接数据库
 * @returns {Promise<Object>} MongoDB连接实例
 */
async function connectDB() {
    try {
        // 确保连接池已初始化
        if (!connectionPool.getConnectionStatus().mongodb.connected) {
            await connectionPool.init();
        }
        return connectionPool.getMongoConnection();
    } catch (error) {
        console.error('数据库连接失败:', error);
        throw error;
    }
}

module.exports = {
    connectDB
};